package cc.autoapi.pucong.auto.flow.core.flow.execNode.exec.publish;

import cc.autoapi.pucong.auto.flow.core.flow.execNode.entity.node.NodeHandlerMsgDto;
import cc.autoapi.pucong.auto.flow.core.flow.execNode.eventBus.IPublisher;
import cc.autoapi.pucong.auto.flow.core.flow.execNode.selfenum.MsgTypeEnum;

/**
 * api 处理器
 */
public class ProcessExecNodePublish implements IPublisher<NodeHandlerMsgDto> {

    @Override
    public String getMessageType() {
        return MsgTypeEnum.NODE_MSG.getType();
    }

    /**
     * 同步处理
     *
     * @param message 消息实体
     */
    @Override
    public void publishMessage(NodeHandlerMsgDto message) {
        IPublisher.super.publishMessage(message);
    }

    /**
     * 异步处理
     *
     * @param message 消息实体
     */
    @Override
    public void publicMessageByAsync(NodeHandlerMsgDto message) {
        IPublisher.super.publicMessageByAsync(message);
    }
}
